#include "sqlFun.h"
#include <stdio.h>
#include <string.h>
#include <uuid/uuid.h>

void createTable(MYSQL *mysqlSt)
{
	/*
	//向数据库中插入一条记录  
    intres = mysql_query(mysqlSt,    
        "CREATE TABLE words ( \
    id       VARCHAR( 36 )  NOT NULL,\
    word     VARCHAR( 20 ),\
    datetime DATETIME,\
    time     VARCHAR( 30 ) \
);");  
    if( res != 0 )   
    {
    	  perror("result error.");  
           return;
    }
        // MYSQL_RES *res=
        */
}
void check_db(MYSQL *mysqlSt,char *db_name)
{
	MYSQL_ROW row=NULL;
	MYSQL_RES *res=NULL;

	res=mysql_list_dbs(mysqlSt,NULL);
	if(res!=NULL)
	{
		while((row=mysql_fetch_row(res)))
		{
			printf("db is %s\n",row[0]);
			if(strcmp(row[0],db_name)==0)
			{
				printf("find db %s\n",db_name);
				break;
			}
		}

		mysql_free_result(res);
	}

//create db_name
	if(!row)
	{
		char buf[128]={0};
		strcpy(buf,"create database ");
		strcat(buf,db_name);

		if(0!=mysql_query(mysqlSt,buf))
		{
			printf("check_db failed:");
			mysql_error(mysqlSt);
			return;
		}
	}

}
void check_table(MYSQL *mysqlSt,char *table_name)
{
	if(table_name==NULL)
		return ;
	
	MYSQL_ROW row;
	MYSQL_RES *res=NULL;
	
	res=mysql_list_tables(mysqlSt,NULL);
	if(res!=NULL)
	{
		while((row=mysql_fetch_row(res))!=NULL)
		{
			printf("tables is %s\n",row[0]);
			if(strcmp(row[0],table_name)==0)
			{
				printf("find the table.\n");
				return;
			}
		}
		mysql_free_result(res);
	}
	
	// if(!row)
	{
		char buf[128]={0};
		snprintf(buf,sizeof(buf),
			"create table %s (id varchar(36) not null,\
			word varchar(20),\
			datetime datetime,\
			time varchar(30));",table_name);

		printf("check_table buf:%s\n",buf);

		if(0!=mysql_query(mysqlSt,buf))
		{
			printf("check_table error:");
			mysql_error(mysqlSt);
			return;
		}
		else 
			printf("create table ok.\n");
	}

}
void showDatabases(MYSQL *mysqlSt)
{
	MYSQL_ROW row=NULL;
	MYSQL_RES *res=NULL;

	res=mysql_list_dbs(mysqlSt,NULL);
	if(res!=NULL)
	{
		while((row=mysql_fetch_row(res)))
		{
			printf("showDatabases：%s\n",row[0]);
		}

		mysql_free_result(res);
	}
}
void showTables(MYSQL *mysqlSt,char *db_name)
{
	MYSQL_ROW row;
	MYSQL_RES *res=NULL;

	if(0!=mysql_select_db(mysqlSt,db_name))
	{
		perror("mysql_select_db error.");
		mysql_error(mysqlSt);
		return;
	}
	
	res=mysql_list_tables(mysqlSt,NULL);
	if(res!=NULL)
	{
		while((row=mysql_fetch_row(res)))
		{
			printf("show tables： %s\n",row[0]);
		}

		mysql_free_result(res);
	}
}

void insertValue(MYSQL *mysqlSt)
{

}

